package com.sbp.message.service;

import com.sbp.message.api.entity.LocalRecordStatus;
import com.sbp.message.entity.ConsumerMessageRecord;

import java.util.Date;

public interface ConsumerMessageRecordService {
	void insert(ConsumerMessageRecord record);

	int updateStatus(String messageId, LocalRecordStatus status);

	ConsumerMessageRecord selectOne(String messageId);

	void delete(String messageId);
	int deleteRecordBeforeTime(Date date);

}
